sequenceDiagram
    participant Client
    participant Encoder as Graph Encoder
    participant Writer as BufferedWriter
    participant Redis as RDB Storage
    
    Client->>Encoder: rdb_save_graph(graph)
    Encoder->>Encoder: Build payload directory
    Encoder->>Writer: new(rdb_io)
    Encoder->>Writer: write_unsigned (header fields)
    Encoder->>Writer: write_buffer (schema)
    Encoder->>Writer: write_unsigned/write_buffer (payloads)
    loop For each payload
        Encoder->>Encoder: encode_payload(graph)
        Encoder->>Writer: write_unsigned/write_buffer
    end
    Writer-->>Redis: flush on buffer overflow (256KB)
    Encoder->>Writer: finish()
    Writer-->>Redis: final chunk
    Encoder-->>Client: Done

sequenceDiagram
    participant Client
    participant Decoder as Graph Decoder
    participant Reader as BufferedReader
    participant Redis as RDB Storage
    participant State as DECODE_STATE
    
    Client->>Decoder: rdb_load_graph(rdb)
    Redis-->>Reader: load_string_buffer (chunk 0)
    Reader->>Decoder: parse Header/Schema
    
    alt Single Key (key_count == 1)
        Decoder->>Reader: read payloads
        Decoder->>Decoder: decode_payloads (to local stores)
        Decoder->>Decoder: finalize (commit attrs, rebuild indexes)
        Decoder-->>Client: return Graph
    else Multi Key (key_count > 1)
        Decoder->>State: init PendingGraph (key 0)
        Decoder->>Reader: read/decode payloads
        Decoder->>State: store in pending_graph
        State-->>Decoder: keys_remaining--
        Decoder->>Client: return None
        Client->>Decoder: rdb_load_graph(key N)
        Decoder->>State: load PendingGraph
        Decoder->>Reader: read/decode payloads
        Decoder->>State: merge into pending_graph
        Note over State: When keys_remaining == 0
        Decoder->>Decoder: finalize_pending_graph()
        Decoder->>State: store finalized Graph
    end